package cc.permission.service;

import cc.cloudapi.permission.proto.user.UserServiceGrpc;
import cc.permission.other.GrpcService;
import cc.permission.repository.UserRepository;


/**
 * 描述:
 *
 * @author wangyan
 * @date 2020/4/1
 */

@GrpcService
public class UserGrpcService extends UserServiceGrpc.UserServiceImplBase{
    private UserRepository userRepository;

//    @Override
//    public void userAdd(UserAddEntity request, StreamObserver<IntegerEntity> responseObserver) {
//        System.out.println("service:" + request.getLastmodifytime());
//        IntegerEntity builder = IntegerEntity.newBuilder().setIntEnt(1).build();
//        // 返回
//        responseObserver.onNext(builder);
//        // 指出我们已经完成了和 RPC的交互
//        responseObserver.onCompleted();
//    }
//
//    /**
//     * 修改用户
//     * @author muxiaoxue
//     * @param request
//     * @param responseObserver
//     */
//    @Override
//    public void userUpdate(UserUpdateEntity request, StreamObserver<IntegerEntity> responseObserver){
//        User user = userRepository.get(request.getNid());
//        if (user != null){
//            user.setVid(request.getVid());
//            user.setPassword(request.getPassword());
//            user.setUserName(request.getUsername());
//            user.setMobile(request.getMobile());
//            user.setLastModifyTime(request.getLastmodifytime());
//            user.setStatus(Byte.parseByte(String.valueOf(request.getStatus())));
//            userRepository.update(user);
//        }
//        IntegerEntity builder = IntegerEntity.newBuilder().setIntEnt(1).build();
//        responseObserver.onNext(builder);
//    }

//    @Override
//    public void userGet(UserGetEntity request, StreamObserver<UserGetValue> responseObserver){
//        User user = userRepository.get(request.getNid());
//        if (user != null){
//            UserGetValue userGetValue = UserGetValue.newBuilder().setVid(user.getVid())
//                    .setPassword(user.getPassword())
//                    .setUsername(user.getUserName())
//                    .setMobile(user.getMobile())
//                    .setLastmodifytime(user.getLastModifyTime())
//                    .setStatus().build();
//        }
//
//
//    }
}
